package my.syncfilter;

public interface FileProcessor<T> extends Runnable {
    //处理,返回true 继续下一个连，否则退出
    boolean process(T data);

    boolean submit(T t);

    void next(Object o);

    boolean ifExit(T t);

    boolean ifParallel();

    void setParallel(boolean p);

}